package com.wu.xtkong.producer;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.json.JSONObject;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.wu.xtkong.domain.User;

/** 
* @author 吴冬冬 
* @version 创建时间：2017年4月27日 下午3:51:12 
* 生产消息给exchanges
*/
@Component
public class Sender {
    @Autowired
    private AmqpTemplate rabbitTemplate;
    
    public void send() {
    	Date date= new Date();
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
		String context = "发送时间： " + sdf.format(date);
        System.out.println("Sender  : " + context);
        this.rabbitTemplate.convertAndSend("hello", context);
    }
    
    public void sendList() {
    	for(int i=0;i<20;i++){
    		Date date= new Date();
    		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
    		String context = "任务"+i+"时间： " + sdf.format(date);
            System.out.println("Sender : " + context);
            this.rabbitTemplate.convertAndSend("sendList", context);
    	}
    }
    
    /**
     * 发送对象数据
     */
    public void sendUser() {
    	User u = new User("小天空","男","18");
        System.out.println("sendUser  : " + u.getName());
        this.rabbitTemplate.convertAndSend("user", u);
    }
}
